package com.idudiao.sc.stream.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @author: 读钓
 * @date 2018-11-30 23:23
 */
@EnableBinding({TestSender.class, TestCallBack.class})
@Slf4j
public class ProducerReceiver {

    @StreamListener(TestCallBack.INPUT)
    public void process(String message) {
        log.info("【sc-producer】ProducerReceiver 接收到消息: {}", message);
    }
}